package cn.rui.service;

import cn.dev33.satoken.stp.SaTokenInfo;
import cn.dev33.satoken.stp.StpUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.rui.common.ContentBean;
import cn.rui.common.ResponseBean;
import cn.rui.error.DisableException;
import cn.rui.mapper.UserMapper;
import cn.rui.pojo.User;
import cn.rui.pojo.vo.PageVo;
import cn.rui.pojo.vo.UpdatePassVo;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;

import javax.servlet.http.HttpSession;
import java.io.UnsupportedEncodingException;
import java.util.*;

/**
 * @author 徽州大都督
 * @date 2021/6/8
 */
@Service
@Transactional(rollbackFor = Exception.class)
public class UserService extends ServiceImpl<UserMapper,User> {

    @Autowired
    private UserMapper userMapper;

    @Autowired
    private AsyncService asyncService;

    public ResponseBean login(String username, String password, HttpSession session) {

        QueryWrapper<User> wrapper = new QueryWrapper<> ();
        wrapper.eq ("username", username);
        User user = userMapper.selectOne (wrapper);

        if (!ObjectUtils.isEmpty (user)) {
            //密码错误
            if (!user.getPassword ().equals (password)) {
                //保存登录日志
                asyncService.saveLoginLog (ContentBean.AccountPassEroor, username, 0);
                return ResponseBean.error (ContentBean.AccountPassEroor, 401);
            }

            //账号禁用
            if (user.getStatus () == 1) {
                //保存登录日志
                asyncService.saveLoginLog (ContentBean.AccountDisabled, username, 0);
                throw new DisableException (ContentBean.AccountDisabled);
            }

            //将用户名存到session中
            session.setAttribute ("username", username);

            //保存登录日志
            asyncService.saveLoginLog (ContentBean.LoginSuccess, username, 1);

            //更新登录时间
            user.setUpdateTime (new Date ());

            userMapper.updateById (user);
            StpUtil.setLoginId (user.getUsername ());
            SaTokenInfo tokenInfo = StpUtil.getTokenInfo ();

            Map map = new HashMap ();
            map.put ("user", user);
            map.put ("tokenInfo", tokenInfo);

            return ResponseBean.success (ContentBean.LoginSuccess, map);
        }
        return ResponseBean.error (ContentBean.AccountUserNotExise, 401);
    }

    public ResponseBean findPage(PageVo pageVo, HttpSession session) {

        /* 598 百家姓 */
//        String[] Surname= {"赵","钱","孙","李","周","吴","郑","王","冯","陈","褚","卫","蒋","沈","韩","杨","朱","秦","尤","许",
//                "何","吕","施","张","孔","曹","严","华","金","魏","陶","姜","戚","谢","邹","喻","柏","水","窦","章","云","苏","潘","葛","奚","范","彭","郎",
//                "鲁","韦","昌","马","苗","凤","花","方","俞","任","袁","柳","酆","鲍","史","唐","费","廉","岑","薛","雷","贺","倪","汤","滕","殷",
//                "罗","毕","郝","邬","安","常","乐","于","时","傅","皮","卞","齐","康","伍","余","元","卜","顾","孟","平","黄","和",
//                "穆","萧","尹","姚","邵","湛","汪","祁","毛","禹","狄","米","贝","明","臧","计","伏","成","戴","谈","宋","茅","庞","熊","纪","舒",
//                "屈","项","祝","董","梁","杜","阮","蓝","闵","席","季","麻","强","贾","路","娄","危","江","童","颜","郭","梅","盛","林","刁","钟",
//                "徐","邱","骆","高","夏","蔡","田","樊","胡","凌","霍","虞","万","支","柯","昝","管","卢","莫","经","房","裘","缪","干","解","应",
//                "宗","丁","宣","贲","邓","郁","单","杭","洪","包","诸","左","石","崔","吉","钮","龚","程","嵇","邢","滑","裴","陆","荣","翁","荀",
//                "羊","于","惠","甄","曲","家","封","芮","羿","储","靳","汲","邴","糜","松","井","段","富","巫","乌","焦","巴","弓","牧","隗","山",
//                "谷","车","侯","宓","蓬","全","郗","班","仰","秋","仲","伊","宫","宁","仇","栾","暴","甘","钭","厉","戎","祖","武","符","刘","景",
//                "詹","束","龙","叶","幸","司","韶","郜","黎","蓟","溥","印","宿","白","怀","蒲","邰","从","鄂","索","咸","籍","赖","卓","蔺","屠",
//                "蒙","池","乔","阴","郁","胥","能","苍","双","闻","莘","党","翟","谭","贡","劳","逄","姬","申","扶","堵","冉","宰","郦","雍","却",
//                "璩","桑","桂","濮","牛","寿","通","边","扈","燕","冀","浦","尚","农","温","别","庄","晏","柴","瞿","阎","充","慕","连","茹","习",
//                "宦","艾","鱼","容","向","古","易","慎","戈","廖","庾","终","暨","居","衡","步","都","耿","满","弘","匡","国","文","寇","广","禄",
//                "阙","东","欧","殳","沃","利","蔚","越","夔","隆","师","巩","厍","聂","晁","勾","敖","融","冷","訾","辛","阚","那","简","饶","空",
//                "曾","毋","沙","乜","养","鞠","须","丰","巢","关","蒯","相","查","后","荆","红","游","郏","竺","权","逯","盖","益","桓","公","仉",
//                "督","岳","帅","缑","亢","况","郈","有","琴","归","海","晋","楚","闫","法","汝","鄢","涂","钦","商","牟","佘","佴","伯","赏","墨",
//                "哈","谯","篁","年","爱","阳","佟","言","福","南","火","铁","迟","漆","官","冼","真","展","繁","檀","祭","密","敬","揭","舜","楼",
//                "疏","冒","浑","挚","胶","随","高","皋","原","种","练","弥","仓","眭","蹇","覃","阿","门","恽","来","綦","召","仪","风","介","巨",
//                "木","京","狐","郇","虎","枚","抗","达","杞","苌","折","麦","庆","过","竹","端","鲜","皇","亓","老","是","秘","畅","邝","还","宾",
//                "闾","辜","纵","侴","万俟","司马","上官","欧阳","夏侯","诸葛","闻人","东方","赫连","皇甫","羊舌","尉迟","公羊","澹台","公冶","宗正",
//                "濮阳","淳于","单于","太叔","申屠","公孙","仲孙","轩辕","令狐","钟离","宇文","长孙","慕容","鲜于","闾丘","司徒","司空","兀官","司寇",
//                "南门","呼延","子车","颛孙","端木","巫马","公西","漆雕","车正","壤驷","公良","拓跋","夹谷","宰父","谷梁","段干","百里","东郭","微生",
//                "梁丘","左丘","东门","西门","南宫","第五","公仪","公乘","太史","仲长","叔孙","屈突","尔朱","东乡","相里","胡母","司城","张廖","雍门",
//                "毋丘","贺兰","綦毋","屋庐","独孤","南郭","北宫","王孙"};
//
//
//        //System.out.println (ele+getChinese ());
//        for (int i = 0; i < 500; i++) {
//            String ele = RandomUtil.randomEle (Surname);
//            User user = new User ();
//            String ss = "620102198204175014";
//            String username = RandomUtil.randomNumbers (ss.length ());
//            user.setUsername (username);
//            user.setRealName (ele+getChinese ());
//            user.setRegion ("合肥市");
//            user.setPhoneNumber (RandomUtil.randomNumbers (11));
//            user.setSex ("0");
//            user.setPassword ("123456");
//            user.setStatus (0);
//            user.setDelFlag (1);
//            user.setUpdateTime (new Date ());
//            user.setCreateTime (new Date ());
//            userMapper.insert (user);
//            System.out.println ("插入成功"+i);
//        }


        QueryWrapper<User> wrapper = new QueryWrapper<> ();
        Page<User> page = new Page<> (pageVo.getCurrentPage (), pageVo.getPageSize ());

        if (StrUtil.isNotEmpty (pageVo.getQueryContent ())) {
            wrapper.like ("real_name", pageVo.getQueryContent ());
        }

        //排除当前登录账号
        String username = (String) session.getAttribute ("username");
        if (StrUtil.isNotEmpty (username)) {
            wrapper.ne ("username", username);
        }

        wrapper.orderByDesc ("create_time");

        IPage<User> userIPage = userMapper.selectPage (page, wrapper);

        PageVo pv = new PageVo ();

        pv.setTotal (userIPage.getTotal ());

        List<User> userList = userIPage.getRecords ();

        pv.setData (userList);

        return ResponseBean.success (ContentBean.QuerySuccess, pv);
    }

    public ResponseBean updateRemark(Integer userId, String remark) {

        List<User> users = userMapper.selectList (null);
        for (User user : users) {
            if (user.getDelFlag () == 0) {
                user.setDelFlag (1);
                userMapper.updateById (user);
            }

        }

        Map map = new HashMap ();
        map.put ("userId", userId);
        map.put ("remark", remark);
        userMapper.updateRemark (map);
        return ResponseBean.success (ContentBean.UpdateSuccess);
    }

    public ResponseBean deleteById(Integer id) {
        userMapper.deleteById (id);

        return ResponseBean.success (ContentBean.DeleteSuccess);
    }

    public ResponseBean updateStatus(Integer id) {
        User user = userMapper.selectById (id);
        if (user.getStatus () == 0) {
            user.setStatus (1);
        } else {
            user.setStatus (0);
        }

        userMapper.updateById (user);

        return ResponseBean.success (ContentBean.OperationSuccess);
    }


    public ResponseBean writeNote(String content, HttpSession session) {
        String username = (String) session.getAttribute ("username");
        if (StrUtil.isNotEmpty (username)) {
            Map map = new HashMap ();
            map.put ("content", content);
            map.put ("username", username);
            userMapper.updateWriteNote (map);
        }

        return ResponseBean.success (ContentBean.UpdateSuccess);
    }

    public ResponseBean updatePass(UpdatePassVo updatePassVo, HttpSession session) {
        String username = (String) session.getAttribute ("username");
        QueryWrapper<User> wrapper = new QueryWrapper<> ();
        wrapper.eq ("username", username).eq ("password", updatePassVo.getOldPass ());
        User user = userMapper.selectOne (wrapper);
        if (ObjectUtil.isEmpty (user)) {
            return ResponseBean.error (ContentBean.UpdateEoor, 301);
        }

        //发送邮件
        asyncService.sendMail ();

        user.setPassword (updatePassVo.getNewPass ());
        userMapper.updateById (user);

        return ResponseBean.success (ContentBean.UpdateSuccess);
    }


    public static String getChinese() {
        String str = null;
        int highPos, lowPos;
        Random random = new Random();
        highPos = (176 + Math.abs(random.nextInt(71)));//区码，0xA0打头，从第16区开始，即0xB0=11*16=176,16~55一级汉字，56~87二级汉字
        random=new Random ();
        lowPos = 161 + Math.abs(random.nextInt(94));//位码，0xA0打头，范围第1~94列

        byte[] bArr = new byte[2];
        bArr[0] = (new Integer(highPos)).byteValue();
        bArr[1] = (new Integer(lowPos)).byteValue();
        try {
            str = new String(bArr, "GB2312");	//区位码组合成汉字
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        return str;
    }

}
